package org.backend.task;

import lombok.extern.slf4j.Slf4j;
import org.backend.pojo.vo.MessageVO;
import org.backend.websocket.WxWebSocketHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class SendMessageToClientTestTask {

    @Autowired
    private WxWebSocketHandler wxWebSocketHandler;

//    @Scheduled(fixedRate = 5000)
//    public void sendMessageToClient() {
//        String message = "Hello World : " + System.currentTimeMillis();
//        List<Integer> list = new ArrayList<>();
//        list.add(1);
//        list.add(2);
//        list.add(3);
//        // 向所有已连接的用户发送消息
//        wxWebSocketHandler.getAllOpenids().forEach(openid -> {
//            wxWebSocketHandler.sendNotificationToUser(openid, message, list);
//        });
//    }

    /**
     * 消息页面实时监听测试
     */
//    @Scheduled(fixedRate = 5000)
//    public void messageTest() {
//        MessageVO webSocketContentVO = new MessageVO();
//        MessageVO.Data1 data1 = new MessageVO.Data1();
//        data1.setBuyerName("slxner");
//        data1.setProductName("Porsche");
//        data1.setProductId(1);
//        webSocketContentVO.setData(data1);
//        webSocketContentVO.setType("purchase_goods");
//        String message = "测试用例";
//        log.info("消息页面监听测试");
//        wxWebSocketHandler.getAllOpenids().forEach(openid -> {
//            wxWebSocketHandler.sendNotificationToUser(openid, message, webSocketContentVO);
//        });
//    }
}
